package com.lesg.search

import org.apache.spark.{SparkConf, SparkContext}
import org.slf4j.LoggerFactory

object glueEntry {

  val logger =   LoggerFactory.getLogger(glueEntry.getClass)

  def main(args: Array[String]): Unit = {
    logger.info("Arguments: ")
    logger.info("****************************")

    logger.info("****************************")

    val conf = new SparkConf().setAppName("appName")
    val sc = new SparkContext(conf)
    val index = "http://hdcs-analytics-search-elastic.int.thomsonreuters.com:9200/cat_loan_instrument_fixedincome_loan_0.0.9"
    val documentType = "instrument_fixedincome_loan"
    val documentId = "47333252166"
    ElasticExecutor.getDocContentById(index,documentType,documentId)

  }
}
